其他
高速飞机上换引擎,MQ如何实现平滑迁移?
这个需求估计还挺普遍的,这里分享一些经验。
MQ-client::SendMsg(topic, msg);
MQ-client::RecvMsg(topic, msg, CALLBACK_FUNC);
发送方mq-client
MQ-server
接收方mq-client
粉色是旧MQ体系
蓝色是新MQ体系
ActiveMQ-client::SendMsg(topic, msg);
ActiveMQ-client::RecvMsg(topic, msg, CALLBACK_FUNC);
ShenJianMQ::SendMsg(topic, msg){
ActiveMQ-client::SendMsg(topic,msg);
}
ShenJianMQ::RecvMsg(topic, msg,CALLBACK_FUNC)
ActiveMQ-client::RecvMsg(topic,msg, CALLBACK_FUNC);
}
ShenJianMQ::RecvMsg(topic, msg,CALLBACK_FUNC)
ActiveMQ-client::RecvMsg(topic, msg, CALLBACK_FUNC);
RabbitMQ-client::RecvMsg(topic, msg, CALLBACK_FUNC);
}
ShenJianMQ::SendMsg(topic, msg){
RabbitMQ-client::SendMsg(topic, msg);
}
ShenJianMQ::RecvMsg(topic, msg,CALLBACK_FUNC)
RabbitMQ-client::RecvMsg(topic, msg, CALLBACK_FUNC);
}
画外音:浅浅封装一层之后,监控/告警/数据收集等工作都更容易统一实现了。
知识星球-刚开始玩
画外音:所有提问都会细心解答(如这一篇)。
上次开放了200个名额一下就满了,再开放500个名额(人不宜太多,怕解答不过来)。
相关推荐:
《基础组件,究竟要不要自研?》
《什么时候不能使用MQ》
《究竟什么时候使用MQ》
《MQ消息可达性+幂等性+延时性架构设计》
调研:
贵司有浅浅封装?还是自研?还是原生耦合?